﻿using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace LJ.EventBus.FastDog;

public class EventBusFastDogPackProcessingServer(IEventBusSubscribe eventBusSubscribe) : IPackProcessingServer
{
    private readonly IEventBusSubscribe _eventBusSubscribe = eventBusSubscribe;

    public async Task StartAsync(CancellationToken stoppingToken)
    {
        // 注册事件订阅
        await _eventBusSubscribe.Start(stoppingToken);
    }

    public void Dispose()
    {
       GC.SuppressFinalize(this);
    }
}
